package dal

import (
	"fmt"

	"public.com/goutil/redisUtil"

	"7qule.com/sd3/CrossServer/src/common/onlinelog"
	"7qule.com/sd3/CrossServer/src/config"
)

var redisPool *redisUtil.RedisPool

func init() {
	// 启动redis管理器
	redisConfig := config.GetDbConfig().GetRedisConfig()

	redisPool = redisUtil.NewRedisPool2("CrossServer", redisConfig)

	if err := redisPool.TestConnection(); err != nil {
		msg := fmt.Sprintf("redis 初始化异常：%v", err.Error())
		onlinelog.ErrorLog(msg)

		// panic(msg)
	}
}

// 获取redis连接池对象
// 返回值:
// *redisUtil.RedisPool:连接池对象
func GetRedisPool() *redisUtil.RedisPool {
	return redisPool
}
